package com.xxl.job.admin.core.scheduler;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
import com.xxl.job.admin.core.thread.JobFailMonitorHelper;
import com.xxl.job.admin.core.thread.JobLogReportHelper;
import com.xxl.job.admin.core.thread.JobRegistryMonitorHelper;
import com.xxl.job.admin.core.thread.JobScheduleHelper;
import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
import com.xxl.job.admin.core.util.I18nUtil;
import com.xxl.job.core.biz.ExecutorBiz;
import com.xxl.job.core.enums.ExecutorBlockStrategyEnum;
import com.xxl.rpc.remoting.invoker.call.CallType;
import com.xxl.rpc.remoting.invoker.reference.XxlRpcReferenceBean;
import com.xxl.rpc.remoting.invoker.route.LoadBalance;
import com.xxl.rpc.remoting.net.impl.netty_http.client.NettyHttpClient;
import com.xxl.rpc.serialize.impl.HessianSerializer;

/**
 * @author xuxueli 2018-10-28 00:18:17
 */
public class XxlJobScheduler {

	private static final Logger logger = LoggerFactory.getLogger(XxlJobScheduler.class);

	public void init() throws Exception {
		// init i18n
		initI18n();
		// admin registry monitor run
		JobRegistryMonitorHelper.getInstance().start();
		// admin monitor run
		JobFailMonitorHelper.getInstance().start();
		// admin trigger pool start
		JobTriggerPoolHelper.toStart();
		// admin log report start
		JobLogReportHelper.getInstance().start();
		// start-schedule
		JobScheduleHelper.getInstance().start();
		logger.info(">>>>>>>>> init xxl-job admin success.");
	}

	public void destroy() throws Exception {
		// stop-schedule
		JobScheduleHelper.getInstance().toStop();
		// admin log report stop
		JobLogReportHelper.getInstance().toStop();
		// admin trigger pool stop
		JobTriggerPoolHelper.toStop();
		// admin monitor stop
		JobFailMonitorHelper.getInstance().toStop();
		// admin registry stop
		JobRegistryMonitorHelper.getInstance().toStop();
	}
	// ---------------------- I18n ----------------------

	private void initI18n() {
		for (ExecutorBlockStrategyEnum item : ExecutorBlockStrategyEnum.values()) {
			item.setTitle(I18nUtil.getString("jobconf_block_".concat(item.name())));
		}
	}

	// ---------------------- executor-client ----------------------
	private static ConcurrentMap<String, ExecutorBiz> executorBizRepository = new ConcurrentHashMap<>();

	public static ExecutorBiz getExecutorBiz(String address) throws Exception {
		// valid
		if (address == null || address.trim().length() == 0) {
			return null;
		}
		// load-cache
		address = address.trim();
		ExecutorBiz executorBiz = executorBizRepository.get(address);
		if (executorBiz != null) {
			return executorBiz;
		}
		// set-cache
		XxlRpcReferenceBean referenceBean = new XxlRpcReferenceBean();
		referenceBean.setClient(NettyHttpClient.class);
		referenceBean.setSerializer(HessianSerializer.class);
		referenceBean.setCallType(CallType.SYNC);
		referenceBean.setLoadBalance(LoadBalance.ROUND);
		referenceBean.setIface(ExecutorBiz.class);
		referenceBean.setVersion(null);
		referenceBean.setTimeout(3000);
		referenceBean.setAddress(address);
		referenceBean.setAccessToken(XxlJobAdminConfig.getAdminConfig().getAccessToken());
		referenceBean.setInvokeCallback(null);
		referenceBean.setInvokerFactory(null);
		executorBiz = (ExecutorBiz) referenceBean.getObject();
		executorBizRepository.put(address, executorBiz);
		return executorBiz;
	}
}
